<?php
/**
 * 数据库操作类
 *
 * @authors yutent (yutent@doui.cc)
 * @date    2014-08-31 17:29:56
 * 
 * 
 */

class Do_Mysql {

    //查询次数
    private $counts = 0;

    //内部数据连接对象
    private $conn;

    //内部数据结果
    private $result;

    //内部实例对象
    private static $init = NULL;

    //日志对象
    private $Log;

    //数据库信息
    private static $db;


    private function __construct() {
        
        $this->Log = new Do_Log('mysql_error.log');

        if (!function_exists('mysql_connect')) {
            $this->Log->write('服务器PHP不支持MySql数据库');
        }
        if (!$this->conn = @mysql_connect(self::$db['host'], self::$db['user'], self::$db['passwd'])) {
            $this->Log->write("连接数据库失败,可能是数据库用户名或密码错误");
        }
        if ($this->get_version() > '4.1') {
            mysql_query("SET NAMES 'utf8'");
        }
        @mysql_select_db(self::$db['dbname'], $this->conn) OR $this->Log->write('未找到指定数据库[' . self::$db['dbname'] . ']');
    }

    /**
     * 静态方法，返回数据库连接实例
     */
    public static function init($name = 'default') {
        global $_G;

        self::$db = $_G['db'][$name];

        if (self::$init == NULL) {
            self::$init = new Do_Mysql;
        }
        return self::$init;
    }

    /**
     * 关闭数据库连接
     */
    function close() {
        return mysql_close($this->conn);
    }

    /**
     * 发送查询语句
     *
     */
    function query($sql) {
        $this->result = @mysql_query($sql, $this->conn);
        $this->counts++;
        if (!$this->result) {
            $this->Log->write('SQL语句执行错误：' . $sql . '。 ' . $this->get_error());
            return FALSE;
        }else {
            return $this->result;
        }
    }

    /**
     * 从结果集中取得一行作为关联数组/数字索引数组
     *
     */
    function fetch_array($query , $type = MYSQL_ASSOC) {
        return mysql_fetch_array($query, $type);
    }

    function once_fetch_array($sql) {
        $this->result = $this->query($sql);
        return $this->fetch_array($this->result);
    }

    /**
     * 从结果集中取得一行作为数字索引数组
     *
     */
    function fetch_row($query) {
        return mysql_fetch_row($query);
    }

    /**
     * 取得行的数目
     *
     */
    function num_rows($query) {
        return mysql_num_rows($query);
    }

    /**
     * 取得结果集中字段的数目
     */
    function num_fields($query) {
        return mysql_num_fields($query);
    }
    /**
     * 取得上一步 INSERT 操作产生的 ID
     */
    function insert_id() {
        return mysql_insert_id($this->conn);
    }

    /**
     * 获取mysql错误
     */
    function get_error() {
        return mysql_error();
    }

    /**
     * 获取影响的行数
     */
    function affected_rows() {
        return mysql_affected_rows();
    }

    /**
     * 取得数据库版本信息
     */
    function get_version() {
        return mysql_get_server_info();
    }

    /**
     * 取得数据库查询次数
     */
    function get_count() {
        return $this->counts;
    }
}
